// var kafka = require('kafka-node');

// const Kafka = require('node-rdkafka');

module.exports = app => {
  app.beforeStart(async () => {

    app.rfid = 246634024 
    // 启动Kafka消费者服务
    // var consumer = new Kafka.KafkaConsumer({
    //   'api.version.request': 'true',
    //   'bootstrap.servers': 'ckafka-xjvq57g8.ap-guangzhou.ckafka.tencentcloudmq.com:50001',
    //   'security.protocol': 'SASL_PLAINTEXT',
    //   'sasl.mechanisms': 'PLAIN',
    //   'message.max.bytes': 32000,
    //   'fetch.message.max.bytes': 32000,
    //   'max.partition.fetch.bytes': 32000,
    //   'sasl.username': 'ckafka-xjvq57g8#abc',
    //   'sasl.password': 'asd159ASD',
    //   'group.id': 'test_group'
    // });


    // consumer.connect();


    // consumer.on('ready', function () {
    //   console.log("connect ok");
    //   consumer.subscribe('test');
    //   consumer.consume();
    // })


    // consumer.on('data', function (data) {
    //   console.log(data);
    // });


  });

}